package com.Reactor3参考文档.condition;

import reactor.core.publisher.Flux;

public class SkipUntil {

	// 与takeUntil对应，将丢弃原始数据流中的元素，直到断言条件返回true
	// 从一个包含100个连续元素的序列中丢弃1到10的元素
	public static void main(String[] args) {
		Flux.range(1, 100).skipUntil(i -> i > 10).subscribe(System.out::println);
	}

}
